const MYSQL_CONFIG = require('../config/dbconfig');
const mysql = require('mysql')
const pool = mysql.createPool(MYSQL_CONFIG);

function execSQL(sql) {
    return new Promise((resolve, reject) => {
        pool.getConnection((err, connection) => {
            if (err) {
                console.log('连接失败')
            } else {
                connection.query(sql, (err, result) => {
                    if (err) {
                        reject('查询失败', err)
                    } else {
                        console.log('查询成功')
                        resolve(result)
                    }
                    connection.release();
                })
            }
        })
    })
}


// const connection=mysql.createConnection(MYSQL_CONFIG);
//开始连接
// connection.connect();    
//由query隐式连接

//sql处理函数
// try{
//     function execSQL(sql){
//         // 创建promise函数
//         return new Promise((resolve, reject)=>{
//             //执行sql语句
//             connection.query(sql, (err, result) => {
//                 if(err){
//                     reject('mysql错误',err);
//                     return;
//                 }
//                 resolve(result);
//             })
//         })
//         //关闭连接
//         // connection.end();
//         // 返回promise函数
//     }
// }  catch{

// }


module.exports = execSQL